package com.navinfo.tripanalysis.service;

import com.navinfo.tripanalysis.pojo.LoadDataParam;
import com.navinfo.tripanalysis.pojo.AbnormalProtocolPoint;
import org.apache.spark.api.java.JavaPairRDD;
import org.apache.spark.api.java.JavaSparkContext;
import org.apache.spark.sql.SparkSession;
import scala.Tuple2;

import java.io.Serializable;

public interface LoadAbnormalProtocolPointDataService extends Serializable {

    JavaPairRDD<Tuple2<Long,Long>, AbnormalProtocolPoint> load (SparkSession spark, JavaSparkContext jsc , LoadDataParam param);

}
